package com.hqyj.callback;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Component;

/**
 * 项目:rabbitmq-230301-provider
 * 描述:
 * 时间:2023/8/3 16:17
 * 作者:admin
 * 版本:1.0
 **/
@Component
@Slf4j
public class MqReturn implements RabbitTemplate.ReturnCallback {
    /**
     *
     * @param message 消息
     * @param i 消息队列的索引号
     * @param s  回退内容 原因
     * @param s1 交换机名称
     * @param s2 回退的路由地址
     */
    @Override
    public void returnedMessage(Message message, int i, String s, String s1, String s2) {
        log.info("消息{}",message.toString());
        log.info("消息队列的索引号{}",i);
        log.info("回退内容 原因{}",s);
        log.info("交换机名称{}",s1);
        log.info("回退的路由地址{}",s2);

    }
}
